#include "network.h"
#include <pthread.h>

void* run(void* arg)
{
	NetWork* clinw = (NetWork*)arg;
	char msg[MESSAGE_LEN] = {};
	for(;;)
	{
		if(0 >= nrecv(clinw,msg,sizeof(msg)) || !strcmp("quit",msg))
		{
			nclose(clinw);
			printf("\r服务器正在升级!!!\n");
			exit(0);
		}

		printf("\r%s\n",msg);
		printf(">>>");
		fflush(stdout);
	}
}

int main()
{
	NetWork* clinw = nopen(SOCK_STREAM,ADDRESS,PORT,false);

	char msg[MESSAGE_LEN] = {};
	printf("请输入您的昵称：");
	gets(msg);
	nsend(clinw,msg,strlen(msg)+1);

	pthread_t tid;
	pthread_create(&tid,NULL,run,clinw);

	for(;;)
	{
		printf(">>>");
		gets(msg);
		if(0 >= nsend(clinw,msg,strlen(msg)+1) || !strcmp("quit",msg))
		{
			nclose(clinw);
			printf("\r通信结束!!!\n");
			exit(0);
		}
	}
}
